package tjs.study.notes.queue.producer.kafka.myStream;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface MySource {
//    String INPUT = "my-in";
    String OUTPUT = "my-out";

//    @Input(INPUT)//同时定义输入、输出通道会报错Dispatcher has no subscribers
//    SubscribableChannel myInput();
    @Output(OUTPUT)
    MessageChannel myOutput();
}